package cn.juque.common.disruptor;

import cn.juque.common.base.DisruptorBody;

import java.io.IOException;

/**
 * @author nuoka
 * @version 1.0.0
 * <li>IntelliJ IDEA</li>
 * <li></li>
 * @date 2021/8/24 22:57
 **/
public interface IBusinessEventService {
    /**
     * 具体消费者的实现
     * @param disruptorBody 消息体
     * @throws IOException IOException
     */
    void invoke(DisruptorBody disruptorBody) throws IOException;
}
